999c72be0468664c711159cd53deff79e62ee4a1,retrofit-adapters/rxjava/src/test/java/retrofit2/adapter/rxjava/ObservableTest.java,ObservableTest,bodyFailure,#,75
Before Change
server.enqueue(new MockResponse().setSocketPolicy(DISCONNECT_AFTER_REQUEST));
BlockingObservable<String> o = service.body().toBlocking();
try {
o.first();
fail();
} catch (RuntimeException e) {
assertThat(e.getCause()).isInstanceOf(IOException.class);
}
}
After Change
TestSubscriber<String> subscriber = new TestSubscriber<>();
service.body().subscribe(subscriber);
subscriber.assertNoValues();
subscriber.assertError(IOException.class);
}
@Test public void bodyRespectsBackpressure() {